81d281f073b9c5dcd9e8b81bb6befe936fa8ccf7,src/main/java/io/reactivex/internal/operators/observable/ObservableObserveOn.java,ObserveOnObserver,onSubscribe,#Disposable#,82

Before Change


        public void onSubscribe(Disposable s) {
            if (DisposableHelper.validate(this.s, s)) {
                this.s = s;
                actual.onSubscribe(this);
            }
        }

After Change



                queue = new SpscLinkedArrayQueue<T>(bufferSize);

                actual.onSubscribe(this);
            }
        }